package com.yeeiee.config;

import lombok.experimental.UtilityClass;
import org.apache.flink.configuration.ConfigOption;
import org.apache.flink.configuration.ConfigOptions;

@UtilityClass
public class MysqlSourceConfig {

    public ConfigOption<String> catalog = ConfigOptions.key("catalog")
            .stringType()
            .noDefaultValue();

    public ConfigOption<String> tablePath = ConfigOptions.key("tablePath")
            .stringType()
            .noDefaultValue();

}
